package com.iot.kafka.service;

import cn.hutool.json.JSONUtil;
import lombok.Data;
import org.springframework.kafka.core.KafkaTemplate;

import java.util.UUID;

/**
 * 描述：发送实体
 * @author: ruikanwang
 * @date: 2017/11/16 0016 13:02
 * @version: V1.0
 * 注意：本内容仅限于新疆感知科技有限公司内部传阅,禁止外泄以及用于其他的商业目
 * Copyright © 2018-ganinfo. All rights reserved.
 */
@Data
public class IotKafkaService<T,S> {
    private KafkaTemplate<T,S> kafkaTemplate;
    //发送消息方法
    public void send(String topic,S obj) {
        kafkaTemplate.send(topic, obj);
    }
}
